//package com.wdd.myplatform.config.pulsar;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.ApplicationContext;
//import org.springframework.context.ApplicationEvent;
//import org.springframework.context.ApplicationListener;
//import org.springframework.stereotype.Component;
//
///**
// * 后来发现如上代码会导致BUG-> 在更新Nacos配置之后 Consumer会挂掉
// * 经排查发现结果是由于@RefreshScope注解导致，此注解将摧毁Bean，PulsarConsumer和Producer都将被摧毁，只是说Producer将在下⼀次调⽤中完成重启，Consumer则不能重启，因为没有调⽤，那么怎么解决呢?
// *
// * 就是发布系列事件以刷新容器
// * @author wdd 2022/7/19
// */
//@Component
//@Slf4j
//public class RefreshPulsarListener implements ApplicationListener {
//    @Autowired
//    ApplicationContext applicationContext;
//
//    @Override
//    public void onApplicationEvent(ApplicationEvent event) {
//
//        if (event.getSource().equals("__refreshAll__")) {
//            log.info("Nacos配置中心配置修改 重启Pulsar====================================");
//            log.info("重启PulsarClient,{}", applicationContext.getBean("getPulsarClient"));
//            log.info("重启PulsarConsumer,{}", applicationContext.getBean("comment-publish-topic-consumer"));
//            log.info("重启PulsarConsumer,{}", applicationContext.getBean("reply-publish-topic-consumer"));
//        }
//    }
//}
